var express = require('express');
var app = express();
var sql = require('mysql');
var con = sql.createConnection({
    host:'localhost',
    user: 'root',
    password: '',
    database: 'list',
    port: '3306'
});
con.connect();
app.all('*', function (req, res, next) {
    res.header("Access-Control-Allow-Origin", "*");
    res.header("Access-Control-Allow-Headers", "X-Requested-With");
    res.header("Access-Control-Allow-Methods", "PUT,POST,GET,DELETE,OPTIONS");
    res.header("X-Powered-By", '3.2.1');
    res.header("Content-Type", "application/json;charset=utf-8");
    next();
});

// 查询用户名和密码
app.get('/login',function(req,res){
    var sql = "select * from login"
    con.query(sql,function(err,result){
        if(err){
            res.send(err.message)
            return;
        }
        res.send(result)
    })
});

// 插入用户名和密码
app.get('/login/inster',function(req,res){
    const username = req.query.username;
    const password = req.query.password;
    var sql = 'insert into login(id,username,password) values(0,?,?)'
    con.query(sql,[username,password],function(err,result){
        if(err){
            res.send({
                err:'添加失败'
            })
        }
        res.send({
            message: '添加成功'
        })
    })
})

// 查询 User 表中的文章数据
app.get('/User',function(req,res){
    var sql = 'select * from user'
    con.query(sql,function(err,result){
        if(err){
            res.send(err.message)
            return;
        }
        res.send(result)
    })
})

// 发表添加文章
app.get('/User/add',function(req,res){
    const zuo = req.query.zuo;
    const title = req.query.title;
    const time = req.query.time;
    const context = req.query.context;
    const src = req.query.src;
    const sql = 'insert into user(id,zuo,title,time,context,src) values(0,?,?,?,?,?)'
    con.query(sql,[zuo,title,time,context,src],function(err,result){
        if(err){
            res.send({
                err:'发表失败'
            })
        }
        res.send({
            message:'发表成功'
        })
    })
})

// 轮播图接口
app.get('/img',function(req,res){
    const sql = 'select * from img'
    con.query(sql,function(err,result){
        if(err){
            res.send({message:'图片查询失败'})
            return;
        }
        res.send(result)
    })
})

// 精彩图片的接口
app.get('/beautiful',function(req,res){
    const sql = 'select * from beautiful'
    con.query(sql,function(err,result){
        if(err){
            res.send({message:'图片查询失败'})
            return;
        }
        res.send(result)
    })
})

//  根据点赞的数量 进行排名获取数据
app.get('/good',function(req,res){
    const sql = 'SELECT * FROM `user` ORDER BY good DESC LIMIT 0,2'
    con.query(sql,function(err,result){
        if(err){
            res.send({message:'排名查询成功'})
            return;
        }
        res.send(result)
    })
})


// 启动服务器监听端口
var server = app.listen(8081,'127.0.0.1',function(){
    var host = server.address().address
    var port = server.address().port
    console.log('端口为：http://%s:%s',host,port);
})
